package com.jxb.moniDubbo;

import org.apache.dubbo.common.stream.StreamObserver;

import java.io.Serializable;

public class OrderStream implements StreamObserver<String>, Serializable {
    @Override
    public void onNext(String data) {
        // 服务端返回的数据
        System.out.println(data);
    }

    @Override
    public void onError(Throwable throwable) {

    }

    @Override
    public void onCompleted() {
        System.out.println("complete");
    }
}
